<?php  if ( ! defined('BASEPATH')) exit('No direct script access allowed');
/**
 * Initialize the database
 * 
 * @package		XJPHP
 * @category	Database
 * @param 	string
 * @param 	bool	Determines if active record should be used or not
 */
function &DB($params = '', $active_record_override = NULL)
{
	
	// Load the DB config file if a DSN string wasn't passed
	if (is_string($params) AND strpos($params, '://') === FALSE)
	{
		foreach ($_ENV['XJ_CONFIG_DATABASE_PATH'] as $file_path)
		{
			if ( ! file_exists($file_path))
			{
				xj_sys_show_error('The configuration file database.php does not exist.');
			}
			include($file_path);
		}
		if ( ! isset($db) OR count($db) == 0)
		{
			xj_sys_show_error('No database connection settings were found in the database config file.');
		}
	
		if ($params != '')
		{
			$active_group = $params;
		}
	
		if ( ! isset($active_group) OR ! isset($db[$active_group]))
		{
			xj_sys_show_error('You have specified an invalid database connection group.');
		}
		$params = $db[$active_group];
	}
	elseif (is_string($params))
	{
	
		/* parse the URL from the DSN string
		 *  Database settings can be passed as discreet
		*  parameters or as a data source name in the first
		*  parameter. DSNs must have this prototype:
		*  $dsn = 'driver://username:password@hostname/database';
		*/
	
		if (($dns = @parse_url($params)) === FALSE)
		{
			xj_sys_show_error('Invalid DB Connection String');
		}
	
		$params = array(
				'dbdriver'	=> $dns['scheme'],
				'hostname'	=> (isset($dns['host'])) ? rawurldecode($dns['host']) : '',
				'username'	=> (isset($dns['user'])) ? rawurldecode($dns['user']) : '',
				'password'	=> (isset($dns['pass'])) ? rawurldecode($dns['pass']) : '',
				'database'	=> (isset($dns['path'])) ? rawurldecode(substr($dns['path'], 1)) : ''
		);
	
		// were additional config items set?
		if (isset($dns['query']))
		{
			parse_str($dns['query'], $extra);
	
			foreach ($extra as $key => $val)
			{
				// booleans please
				if (strtoupper($val) == "TRUE")
				{
					$val = TRUE;
				}
				elseif (strtoupper($val) == "FALSE")
				{
					$val = FALSE;
				}
	
				$params[$key] = $val;
			}
		}
	}
	
	// No DB specified yet?  Beat them senseless...
	if ( ! isset($params['dbdriver']) OR $params['dbdriver'] != 'pdo')
	{
		xj_sys_show_error('You have not selected a database type to connect to.dbdriver only support pdo.');
	}
	
	// Load the DB classes.  Note: Since the active record class is optional
	// we need to dynamically create a class that extends proper parent class
	// based on whether we're using the active record class or not.
	// Kudos to Paul for discovering this clever use of eval()
	
	if ($active_record_override !== NULL)
	{
		$active_record = $active_record_override;
	}
	// clause and character used for LIKE escape sequences
	if (strpos($params['hostname'], 'mysql') !== FALSE){
		$_like_escape_str = '';
		$_like_escape_chr = '';
		
		//Prior to this version, the charset can't be set in the dsn
		if(xj_is_php('5.3.6'))
		{
			$params['hostname'] .= ";charset=".$params['char_set'];
		}
		
		//Set the charset with the connection options
		$params['options']['PDO::MYSQL_ATTR_INIT_COMMAND'] = "SET NAMES ".$params['char_set'];
	}elseif (strpos($params['hostname'], 'odbc') !== FALSE)
	{
		$_like_escape_str = " {escape '%s'} ";
		$_like_escape_chr = '!';
	}
	else
	{
		$_like_escape_str = " ESCAPE '%s' ";
		$_like_escape_chr = '!';
	}
	empty($params['database']) OR $params['hostname'] .= ';dbname='.$params['database'];
	$trans_enabled = FALSE;
	$_random_keyword = ' RND('.time().')';
	$params['options']['PDO::ATTR_ERRMODE'] = PDO::ERRMODE_SILENT;
	if ($params['pconnect'])$params['options']['PDO::ATTR_PERSISTENT'] = TRUE;
	$DB = FALSE;//xj_sys_show_error(json_encode($params['options']));
	try{
		$DB = new PDO($params['hostname'], $params['username'], $params['password'], $params['options']);
	}catch(PDOException $e){
		xj_sys_show_error('PDO Connection failed: ' . $e->getMessage().'<br />'.$params['hostname']);
	}
	if (strpos($params['hostname'], 'mysql') !== FALSE){
		if (!xj_is_php('5.3.6') && isset($params['char_set']) && $params['char_set'] == TRUE)
		{
			$DB->query("SET NAMES ".$params['char_set']);
		}
		if (isset($params['stricton']) && $params['stricton'] == TRUE)
		{
			$DB->query('SET SESSION sql_mode="STRICT_ALL_TABLES"');
		}
	}
	return $DB;
}
/* End of file DB.php */